package com.umeox.moto.mqtt.event;


import com.umeox.moto.mqtt.base.AError;
import com.umeox.moto.mqtt.request.PersistentRequest;

public interface IOnSubscribeRpcListener {
    IOnSubscribeListener getSubscribeListener();

    void onReceived(String topic, PersistentRequest request, IOnRrpcResponseHandle handler);

    void onResponseSuccess(String topic);

    void onResponseFailed(String topic, AError error);
}
